package com.xinghou.mq.consumer;

import com.xinghou.mq.InterestInterface;
import com.xinghou.platform.server.mq.MqMessage;

/**
 * 消息 interest
 * 
 * @author zhangjinwen 2016年1月6日
 */
public class InterestConsumer  extends AbstractConsumer {
	private InterestInterface  interestInterface;

	public InterestConsumer() {
		interestInterface = this.getBean(InterestInterface.class);
	}

	protected void doWork(String task) {
		 String[] datas = task.split(":");
		 interestInterface.update(Integer.parseInt(datas[0]), datas[1].equals("U"));
	}

}
